package com.jcj.jcjmq.server;

import lombok.AllArgsConstructor;
import lombok.Data;

@AllArgsConstructor
@Data
public class MessageSubscription {
    private String topic;
    private String consumerId;

    private Integer offset=-1;
}
